package UDF

import Source.SensorReading
import org.apache.flink.api.common.functions.RichMapFunction
import org.apache.flink.configuration.Configuration

/**
 * 第一个参数，输入的数据类型
 * 第二个参数，输出的数据类型
 */
class MyRichMapFunction extends RichMapFunction[SensorReading, String] {
  override def map(in: SensorReading): String = in.id + "temperature"

  override def open(parameters: Configuration): Unit = {
    //获取上下文
  }
}
